package com.ntd.study.protocol.emq;

import com.ntd.study.protocol.emq.core.NtdMqttClient;
import com.ntd.study.protocol.emq.factory.NtdMqttClientFactory;
import org.eclipse.paho.client.mqttv3.MqttException;

/**
 * @author liuwenju
 * @date 2021/4/15
 */
public class EmqClientSubDemo {

    public static void main(String[] args) throws MqttException {
        NtdMqttClient ntdMqttClient = new NtdMqttClient(NtdMqttClientFactory.TCP_FM_1883);
        ntdMqttClient.subscribe("demo_data");
        ntdMqttClient.subscribe("site_data");
        ntdMqttClient.subscribe("test");
        ntdMqttClient.subscribe("demo_data123456");
    }


}
